package com.lry.raft;

import com.lry.message.AckMessage;
import com.lry.message.Message;
import com.lry.message.MessageExt;
import com.lry.message.PullMessage;
import com.lry.producer.SendResult;

import java.util.List;

public interface MqRaftService {

    SendResult sendMsg(Message msg);

    List<MessageExt> pullMessage(PullMessage pullMessage);

}
